let express = require("express")
let chat_router = express.Router();
let sqlQuery = require("../mysql/mysql");
// 处理post请求的中间件，用于解析post返回的数据
const bodyParser = require('body-parser')
chat_router.use(bodyParser.urlencoded({extended:false}))
// 1.按照id查询
chat_router.get('/id',async(req,res) => {
  let strSql = "select * from onepice where id = ? ";
  let id = req.query.id;//params拿到浏览器带过来得请求参数，如果是ajax请求，则用res.query.id
  console.log("查询的id="+req.query.id)
  let results = await sqlQuery(strSql ,[id]);// 把sql语句传入，并且传入占位符的参数
 
  
  res.json(Array.from(results));//查询到的数据数组化，并返回json数据
})

module.exports = chat_router








// let express = require("express")
// let chat_router = express.Router();
// let sqlQuery = require("../mysql/mysql");
// http = require('http');

// // routes/chat.js

// var IO = null;
// chat_router.io = function (io) {
//   io.on('connection', (socket) => {
//     //接收数据
//     socket.on('login', function (obj) {
//       console.log(obj.username);
//       // 发送数据
//       socket.emit('relogin', {
//         msg: `你好${obj.username}`,
//         code: 200
//       });
//     });
//   });
//   IO = io;
//   return io;
// }
// login_router.post('/', async (req, res) => {
//   IO.socket
// })
// module.exports = chat_router